package com.yun.zhong.fu.usercenter.rocketmq;

import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Service;

/**
 * @Author RenPu
 * @Date 2021/1/4 17:20
 * @Version 1.0
 * @Description:自定义接口rocketmq的消费者的编写
 **/
@Service
@Slf4j
public class RocketMqConsumerDefeination {
    @StreamListener(MySink.MY_INPUT)
    public void recevice(String messageBody) {
        log.info("自定义接口通过stream收到了消息：messageBody ={}", messageBody);

    }




}
